package cn.acrdpm.consumer;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.context.annotation.PropertySource;

import java.nio.channels.Channel;

/**
 *  消费者
 * @author 张敏
 * @date 2021/3/11
 */
//@Component
@PropertySource("classpath:rabbitmq.properties")
//@RabbitListener(queues = "${com.acrdpm.topicqueue1}", containerFactory="rabbitListenerContainerFactory")
public class TopicConsumer {

    @RabbitHandler
    public void process(Message message, Channel channel){
        System.out.println("First Queue received msg : " );
    }

}
